import os

from celery import Celery

# 指定django配置文件（注意：需要在创建celery对象之前指定）
# 指定好可了才能确保我们的任务函数文件能被扫描到
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")

# 创建celery异步任务的应用(对象),通常一个项目就只创建一个对象就可以
# 参数1：自定义的应用名(对象名)
# 参数2：指定使用redis来保存celery                   第15号库
celery_app = Celery('meiduo',
                    broker='redis://127.0.0.1:6379/15',
                    backend='redis://127.0.0.1:6379/14', # 任务返回值的存储点
                    )

# 指定任务函数对应的包，扫描celery任务tasks.py的文件 调用扫描方法autodiscover_tasks
celery_app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email','celery_tasks.html'])  # 自动的去扫描任务

# 第二种指定方式  加上config.py
# celery_app = Celery('meiduo')
# # 读取配置文件
# celery_app.config_from_object('celery_tasks.config')